<?php
namespace App\Repositories;

use App\Exceptions\BasicException;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Redis;
use function Matrix\add;    //引入hash

class EmChatRepository
{
    private $client_id;
    private $client_secret;
    private $org_name;
    private $app_name;
    private $url;
    //------------------------------------------------------用户体系

    /**
     * 初始化参数
     *
     * @param array $options
     * @param $options ['client_id']
     * @param $options ['client_secret']
     * @param $options ['org_name']
     * @param $options ['app_name']
     * $options 必须有默认值，否则在正式服务器上会报错
     */

    public function __construct($options = null) {
        $this->client_id = isset ($options ['client_id']) ? $options ['client_id'] : env('EMCHAT_CLIENT_ID');
        $this->client_secret = isset ($options ['client_secret']) ? $options ['client_secret'] : env('EMCHAT_CLIENT_SECRET');
        $this->org_name = isset ($options ['org_name']) ? $options ['org_name'] : env('EMCHAT_ORG_NAME');
        $this->app_name = isset ($options ['app_name']) ? $options ['app_name'] : env('EMCHAT_APP_NAME');
        if (!empty ($this->org_name) && !empty ($this->app_name)) {
            $this->url = 'https://a1.easemob.com/' . $this->org_name . '/' . $this->app_name . '/';
        }
    }

    public function getUrl() {
        return $this->url;
    }

    /**
     *获取token
     */
    function getToken() {
        $emchat_token = Redis::get('emchat:token');
        if ($emchat_token !== false) {
            return "Authorization:Bearer " . $emchat_token;
        }

        $options = [
            "grant_type"    => "client_credentials",
            "client_id"     => $this->client_id,
            "client_secret" => $this->client_secret
        ];
        //json_encode()函数，可将PHP数组或对象转成json字符串，使用json_decode()函数，可以将json字符串转换为PHP数组或对象
        $body = json_encode($options);
        //使用 $GLOBALS 替代 global
        $url = $this->url . 'token';
        //$url=$base_url.'token';
        $header = ['Accept:application/json', 'Content-Type:application/json'];
        $tokenResult = $this->postCurl($url, $body, $header);
        //var_dump($tokenResult['expires_in']);
        //return $tokenResult;
        Redis::setex('emchat:token', 86400, $tokenResult['access_token']);

        return "Authorization:Bearer " . $tokenResult['access_token'];

    }

    function token() {
        $options = [
            "grant_type"    => "client_credentials",
            "client_id"     => $this->client_id,
            "client_secret" => $this->client_secret
        ];
        //json_encode()函数，可将PHP数组或对象转成json字符串，使用json_decode()函数，可以将json字符串转换为PHP数组或对象
        $body = json_encode($options);
        //使用 $GLOBALS 替代 global
        $url = $this->url . 'token';
        $header = ['Accept:application/json', 'Content-Type:application/json'];
        $tokenResult = $this->postCurl($url, $body, $header);
        return $tokenResult;

    }

    /**
     * 授权注册
     */
    function createUser($username, $password) {
        $url = $this->url . 'users';
        $options = [
            "username" => $username,
            "password" => $password
        ];
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        批量注册用户
    */
    function createUsers($options) {
        $url = $this->url . 'users';

        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        重置用户密码
    */
    function resetPassword($username, $newpassword) {
        $url = $this->url . 'users/' . $username . '/password';
        $options = [
            "newpassword" => $newpassword
        ];
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, "PUT");
        return $result;
    }

    /*
        获取单个用户
    */
    function getUser($username) {
        $url = $this->url . 'users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        获取批量用户----不分页
    */
    function getUsers($limit = 0) {
        if (!empty($limit)) {
            $url = $this->url . 'users?limit=' . $limit;
        } else {
            $url = $this->url . 'users';
        }
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        获取批量用户---分页
    */
    function getUsersForPage($limit = 0, $cursor = '') {
        $url = $this->url . 'users?limit=' . $limit . '&cursor=' . $cursor;

        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        if (!empty($result["cursor"])) {
            $cursor = $result["cursor"];
            $this->writeCursor("userfile.txt", $cursor);
        }
        //var_dump($GLOBALS['cursor'].'00000000000000');
        return $result;
    }

    //创建文件夹
    function mkdirs($dir, $mode = 0777) {
        if (is_dir($dir) || @mkdir($dir, $mode)) return TRUE;
        if (!$this->mkdirs(dirname($dir), $mode)) return FALSE;
        return @mkdir($dir, $mode);
    }

    //写入cursor
    function writeCursor($filename, $content) {
        //判断文件夹是否存在，不存在的话创建
        if (!file_exists("resource/txtfile")) {
            $this->mkdirs("resource/txtfile");
        }
        $myfile = @fopen("resource/txtfile/" . $filename, "w+") or die("Unable to open file!");
        @fwrite($myfile, $content);
        fclose($myfile);
    }

    //读取cursor
    function readCursor($filename) {
        //判断文件夹是否存在，不存在的话创建
        if (!file_exists("resource/txtfile")) {
            $this->mkdirs("resource/txtfile");
        }
        $file = "resource/txtfile/" . $filename;
        $fp = fopen($file, "a+");//这里这设置成a+
        if ($fp) {
            while (!feof($fp)) {
                //第二个参数为读取的长度
                $data = fread($fp, 1000);
            }
            fclose($fp);
        }
        return $data;
    }

    /*
        删除单个用户
    */
    function deleteUser($username) {
        $url = $this->url . 'users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        删除批量用户
        limit:建议在100-500之间，、
        注：具体删除哪些并没有指定, 可以在返回值中查看。
    */
    function deleteUsers($limit) {
        $url = $this->url . 'users?limit=' . $limit;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;

    }

    /*
        修改用户昵称
    */
    function editNickname($username, $nickname) {
        $url = $this->url . 'users/' . $username;
        $options = [
            "nickname" => $nickname
        ];
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'PUT');
        return $result;
    }

    /*
        添加好友-
    */
    function addFriend($username, $friend_name) {
        $url = $this->url . 'users/' . $username . '/contacts/users/' . $friend_name;
        $header = [$this->getToken(), 'Content-Type:application/json'];
        $result = $this->postCurl($url, '', $header, 'POST');
        return $result;
    }


    /*
        删除好友
    */
    function deleteFriend($username, $friend_name) {
        $url = $this->url . 'users/' . $username . '/contacts/users/' . $friend_name;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;

    }

    /*
        查看好友
    */
    function showFriends($username) {
        $url = $this->url . 'users/' . $username . '/contacts/users';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;

    }

    /*
        查看用户黑名单
    */
    function getBlacklist($username) {
        $url = $this->url . 'users/' . $username . '/blocks/users';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;

    }

    /**
     * 往黑名单中加人
     * $username     发起者环信id，类型：字符串
     * $usernames    被拉黑者环信id，类型：数组
     */
    function addUserForBlacklist($username, $usernames) {
        $url = $this->url . 'users/' . $username . '/blocks/users';
        $options = [
            'usernames' => [
                $usernames
            ]
        ];
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'POST');
        return $result;

    }

    /*
        从黑名单中减人
    */
    function deleteUserFromBlacklist($username, $blocked_name) {
        $url = $this->url . 'users/' . $username . '/blocks/users/' . $blocked_name;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;

    }

    /*
       查看用户是否在线
    */
    function isOnline($username) {
        $url = $this->url . 'users/' . $username . '/status';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;

    }

    /*
        查看用户离线消息数
    */
    function getOfflineMessages($username) {
        $url = $this->url . 'users/' . $username . '/offline_msg_count';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;

    }

    /*
        查看某条消息的离线状态
        ----deliverd 表示此用户的该条离线消息已经收到
    */
    function getOfflineMessageStatus($username, $msg_id) {
        $url = $this->url . 'users/' . $username . '/offline_msg_status/' . $msg_id;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;

    }

    /*
        禁用用户账号
    */
    function deactiveUser($username) {
        $url = $this->url . 'users/' . $username . '/deactivate';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header);
        return $result;
    }

    /*
        解禁用户账号
    */
    function activeUser($username) {
        $url = $this->url . 'users/' . $username . '/activate';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header);
        return $result;
    }

    /*
        强制用户下线
    */
    function disconnectUser($username) {
        $url = $this->url . 'users/' . $username . '/disconnect';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }
    //--------------------------------------------------------上传下载
    /*
        上传图片或文件
    */
    function uploadFile($filePath) {
        $url = $this->url . 'chatfiles';
        $file = file_get_contents($filePath);
        $body['file'] = $file;
        $header = ['enctype:multipart/form-data', $this->getToken(), "restrict-access:true"];
        $result = $this->postCurl($url, $body, $header, 'XXX');
        return $result;

    }

    /*
        下载文件或图片
    */
    function downloadFile($uuid, $shareSecret) {
        $url = $this->url . 'chatfiles/' . $uuid;
        $header = ["share-secret:" . $shareSecret, "Accept:application/octet-stream", $this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        $filename = md5(time() . mt_rand(10, 99)) . ".png"; //新图片名称
        if (!file_exists("resource/down")) {
            //mkdir("../image/down");
            $this->mkdirs("resource/down/");
        }

        $file = @fopen("resource/down/" . $filename, "w+");//打开文件准备写入
        @fwrite($file, $result);//写入
        fclose($file);//关闭
        return $filename;

    }

    /*
        下载图片缩略图
    */
    function downloadThumbnail($uuid, $shareSecret) {
        $url = $this->url . 'chatfiles/' . $uuid;
        $header = ["share-secret:" . $shareSecret, "Accept:application/octet-stream", $this->getToken(), "thumbnail:true"];
        $result = $this->postCurl($url, '', $header, 'GET');
        $filename = md5(time() . mt_rand(10, 99)) . "th.png"; //新图片名称
        if (!file_exists("resource/down")) {
            //mkdir("../image/down");
            $this->mkdirs("resource/down/");
        }

        $file = @fopen("resource/down/" . $filename, "w+");//打开文件准备写入
        @fwrite($file, $result);//写入
        fclose($file);//关闭
        return $filename;
    }



    //--------------------------------------------------------发送消息
    /*
        发送文本消息
    */
    function sendText($from = "admin", $target_type, $target, $content, $ext) {
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "txt";
        $options['msg'] = $content;
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $b, $header);
        return $result;
    }

    /**
     * 发送透传消息
     * @param $from // 发送人
     * @param $target_type // users 给用户发消息。chatgroups 给群发消息，chatrooms 给聊天室发消息
     * @param $target // 注意这里需要用数组，数组长度建议不大于20，即使只有一个用户u1或者群组，
     *                              也要用数组形式 ['u1']，给用户发送时数组元素是用户名，给群组发送时数组元素是groupid
     * @param $action
     * @param $ext
     * @return mixed
     */
    function sendCmd($from = "admin", $target_type, $target, $action, $ext) {
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "cmd";       // 消息类型
        $options['action'] = $action;
        $body['msg'] = $options;
        $body['from'] = $from;
        $ext && $body['ext'] = $ext;
        $b = json_encode($body);
        $header = [$this->getToken()];
        //$b=json_encode($body,true);
        $result = $this->postCurl($url, $b, $header);
        return $result;
    }

    /**
     * 发送扩展消息
     * @param string $from // 发送人
     * @param $target_type // users 给用户发消息。chatgroups 给群发消息，chatrooms 给聊天室发消息
     * @param $target // 注意这里需要用数组，数组长度建议不大于20，即使只有一个用户u1或者群组，
     *                              也要用数组形式 ['u1']，给用户发送时数组元素是用户名，给群组发送时数组元素是groupid
     * @param $message
     * @param $ext
     * @return mixed
     */
    function sendTxt($from = "admin", $target_type, $target, $message, $ext) {
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "txt";       // 消息类型
        $options['msg'] = $message;
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);
        $header = [$this->getToken()];
        //$b=json_encode($body,true);
        $result = $this->postCurl($url, $b, $header);
        return $result;
    }

    /*
        发图片消息
    */
    function sendImage($ext, $filePath, $from = "kouhai", $target_type, $target, $filename) {
        $result = $this->uploadFile($filePath);
        $uri = $result['uri'];
        $uuid = $result['entities'][0]['uuid'];
        $shareSecret = $result['entities'][0]['share-secret'];
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "img";
        $options['url'] = $uri . '/' . $uuid;
        $options['filename'] = time() . '.jpg';
        $options['secret'] = $shareSecret;
        $options['size'] = [
            "width"  => 480,
            "height" => 720
        ];
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);//$b = stripslashes($b);
        $header = [$this->getToken()];//exit($b);
        array_push($header, 'Content-Type:application/json');
        array_push($header, 'Accept:application/json');
        $result = $this->postCurl($url, $b, $header);//exit(json_encode($result));
        return $result;
    }

    /*
        发语音消息
    */
    function sendAudio($ext, $filePath, $from = "kouhai", $target_type, $target, $filename, $length) {
        $result = $this->uploadFile($filePath);
        $uri = $result['uri'];
        $uuid = $result['entities'][0]['uuid'];
        $shareSecret = $result['entities'][0]['share-secret'];
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "audio";
        $options['url'] = $uri . '/' . $uuid;
        $options['filename'] = $filename;
        $options['length'] = $length;
        $options['secret'] = $shareSecret;
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);
        $header = [$this->getToken()];
        //$b=json_encode($body,true);
        $result = $this->postCurl($url, $b, $header);
        return $result;
    }

    /*
        发视频消息
    */
    function sendVedio($ext, $filePath, $from = "kouhai", $target_type, $target, $filename, $length, $thumb, $thumb_secret) {

        $result = $this->uploadFile($filePath);
        $uri = $result['uri'];
        $uuid = $result['entities'][0]['uuid'];
        $shareSecret = $result['entities'][0]['share-secret'];
        $url = $this->url . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "video";
        $options['url'] = $uri . '/' . $uuid;
        $options['filename'] = $filename;
        $options['thumb'] = $thumb;
        $options['length'] = $length;
        $options['secret'] = $shareSecret;
        $options['thumb_secret'] = $thumb_secret;
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);//$b = stripslashes($b);
        $header = [$this->getToken()];
        //$b=json_encode($body,true);
        $result = $this->postCurl($url, $b, $header);
        return $result;
    }

    /*
    发文件消息
    */
    function sendFile($filePath, $from = "admin", $target_type, $target, $filename, $length, $ext) {
        $result = $this->uploadFile($filePath);
        $uri = $result['uri'];
        $uuid = $result['entities'][0]['uuid'];
        $shareSecret = $result['entities'][0]['share-secret'];
        $url = $GLOBALS['base_url'] . 'messages';
        $body['target_type'] = $target_type;
        $body['target'] = $target;
        $options['type'] = "file";
        $options['url'] = $uri . '/' . $uuid;
        $options['filename'] = $filename;
        $options['length'] = $length;
        $options['secret'] = $shareSecret;
        $body['msg'] = $options;
        $body['from'] = $from;
        $body['ext'] = $ext;
        $b = json_encode($body);
        $header = [getToken()];
        //$b=json_encode($body,true);
        $result = postCurl($url, $b, $header);
        return $result;
    }
    //-------------------------------------------------------------群组操作

    /*
        获取app中的所有群组----不分页
    */
    function getGroups($limit = 0) {
        if (!empty($limit)) {
            $url = $this->url . 'chatgroups?limit=' . $limit;
        } else {
            $url = $this->url . 'chatgroups';
        }

        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        获取获取一个用户参与的所有群组
    */
    function joinedGroups($user) {
        $url = $this->url . 'users/' . $user . '/joined_chatgroups';

        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        获取app中的所有群组---分页
    */
    function getGroupsForPage($limit = 0, $cursor = '') {
        $url = $this->url . 'chatgroups?limit=' . $limit . '&cursor=' . $cursor;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");

        if (!empty($result["cursor"])) {
            $cursor = $result["cursor"];
            $this->writeCursor("groupfile.txt", $cursor);
        }

        return $result;
    }

    /*
        获取一个或多个群组的详情
    */
    function getGroupDetail($group_ids) {
        $g_ids = implode(',', $group_ids);
        $url = $this->url . 'chatgroups/' . $g_ids;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        创建一个群组
    */
    function createGroup($options) {
        $url = $this->url . 'chatgroups';
        $header = [$this->getToken()];
        $body = json_encode($options);
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        修改群组信息
    */
    function modifyGroupInfo($group_id, $options) {
        $url = $this->url . 'chatgroups/' . $group_id;
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'PUT');
        return $result;
    }

    /*
        删除群组
    */
    function deleteGroup($group_id) {
        $url = $this->url . 'chatgroups/' . $group_id;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        获取群组中的成员
    */
    function getGroupUsers($group_id) {
        $url = $this->url . 'chatgroups/' . $group_id . '/users';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        群组单个加人
    */
    function addGroupMember($group_id, $username) {
        $url = $this->url . 'chatgroups/' . $group_id . '/users/' . $username;
        $header = [$this->getToken(), 'Content-Type:application/json'];
        $result = $this->postCurl($url, '', $header);
        return $result;
    }

    /*
        群组批量加人
    */
    function addGroupMembers($group_id, $usernames) {
        $url = $this->url . 'chatgroups/' . $group_id . '/users';
        $body = json_encode($usernames);
        $header = [$this->getToken(), 'Content-Type:application/json'];
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        群组单个减人
    */
    function deleteGroupMember($group_id, $username) {
        $url = $this->url . 'chatgroups/' . $group_id . '/users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        群组批量减人
    */
    function deleteGroupMembers($group_id, $usernames) {
        $url = $this->url . 'chatgroups/' . $group_id . '/users/' . $usernames;
        //$body=json_encode($usernames);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        获取一个用户参与的所有群组
    */
    function getGroupsForUser($username) {
        $url = $this->url . 'users/' . $username . '/joined_chatgroups';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        群组转让
    */
    function changeGroupOwner($group_id, $options) {
        $url = $this->url . 'chatgroups/' . $group_id;
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'PUT');
        return $result;
    }

    /*
        查询一个群组黑名单用户名列表
    */
    function getGroupBlackList($group_id) {
        $url = $this->url . 'chatgroups/' . $group_id . '/blocks/users';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        群组黑名单单个加人
    */
    function addGroupBlackMember($group_id, $username) {
        $url = $this->url . 'chatgroups/' . $group_id . '/blocks/users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header);
        return $result;
    }

    /*
        群组黑名单批量加人
    */
    function addGroupBlackMembers($group_id, $usernames) {
        $url = $this->url . 'chatgroups/' . $group_id . '/blocks/users';
        $body = json_encode($usernames);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        群组黑名单单个减人
    */
    function deleteGroupBlackMember($group_id, $username) {
        $url = $this->url . 'chatgroups/' . $group_id . '/blocks/users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        群组黑名单批量减人
    */
    function deleteGroupBlackMembers($group_id, $usernames) {
        $url = $this->url . 'chatgroups/' . $group_id . '/blocks/users';
        $body = json_encode($usernames);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'DELETE');
        return $result;
    }
    //-------------------------------------------------------------聊天室操作
    /*
        创建聊天室
    */
    function createChatRoom($options) {
        $url = $this->url . 'chatrooms';
        $header = [$this->getToken()];
        $body = json_encode($options);
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        修改聊天室信息
    */
    function modifyChatRoom($chatroom_id, $options) {
        $url = $this->url . 'chatrooms/' . $chatroom_id;
        $body = json_encode($options);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header, 'PUT');
        return $result;
    }

    /*
        删除聊天室
    */
    function deleteChatRoom($chatroom_id) {
        $url = $this->url . 'chatrooms/' . $chatroom_id;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        获取app中所有的聊天室
    */
    function getChatRooms() {
        $url = $this->url . 'chatrooms';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        获取一个聊天室的详情
    */
    function getChatRoomDetail($chatroom_id) {
        $url = $this->url . 'chatrooms/' . $chatroom_id;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        获取一个用户加入的所有聊天室
    */
    function getChatRoomJoined($username) {
        $url = $this->url . 'users/' . $username . '/joined_chatrooms';
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    /*
        聊天室单个成员添加
    */
    function addChatRoomMember($chatroom_id, $username) {
        $url = $this->url . 'chatrooms/' . $chatroom_id . '/users/' . $username;
        //$header=array($this->getToken());
        $header = [$this->getToken(), 'Content-Type:application/json'];
        $result = $this->postCurl($url, '', $header);
        return $result;
    }

    /*
        聊天室批量成员添加
    */
    function addChatRoomMembers($chatroom_id, $usernames) {
        $url = $this->url . 'chatrooms/' . $chatroom_id . '/users';
        $body = json_encode($usernames);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, $body, $header);
        return $result;
    }

    /*
        聊天室单个成员删除
    */
    function deleteChatRoomMember($chatroom_id, $username) {
        $url = $this->url . 'chatrooms/' . $chatroom_id . '/users/' . $username;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }

    /*
        聊天室批量成员删除
    */
    function deleteChatRoomMembers($chatroom_id, $usernames) {
        $url = $this->url . 'chatrooms/' . $chatroom_id . '/users/' . $usernames;
        //$body=json_encode($usernames);
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'DELETE');
        return $result;
    }
    //-------------------------------------------------------------聊天记录

    /*
        导出聊天记录----不分页
    */
    function getChatRecord($time) {
        $url = $this->url . 'chatmessages/' . $time;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        return $result;
    }

    /*
        导出聊天记录---分页
    */
    function getChatRecordForPage($ql, $limit = 0, $cursor) {
        if (!empty($ql)) {
            $url = $this->url . 'chatmessages?ql=' . $ql . '&limit=' . $limit . '&cursor=' . $cursor;
        }
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, "GET");
        $cursor = $result["cursor"];
        $this->writeCursor("chatfile.txt", $cursor);
        //var_dump($GLOBALS['cursor'].'00000000000000');
        return $result;
    }

    /**
     *$this->postCurl方法
     */
    function postCurl($url, $body, $header, $type = "POST") {
        //1.创建一个curl资源
        $ch = curl_init();
        //2.设置URL和相应的选项
        curl_setopt($ch, CURLOPT_URL, $url);//设置url
        //1)设置请求头
        //array_push($header, 'Accept:application/json');
        //array_push($header,'Content-Type:application/json');
        //array_push($header, 'http:multipart/form-data');
        //设置为false,只会获得响应的正文(true的话会连响应头一并获取到)
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_TIMEOUT, 5); // 设置超时限制防止死循环
        //设置发起连接前的等待时间，如果设置为0，则无限等待。
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
        //将curl_exec()获取的信息以文件流的形式返回，而不是直接输出。
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        //2)设备请求体
        if ($body) {
            //$b=json_encode($body,true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $body);//全部数据使用HTTP协议中的"POST"操作来发送。
        }
        //设置请求头
        if (count($header) > 0) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
        }
        //上传文件相关设置
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        curl_setopt($ch, CURLOPT_MAXREDIRS, 3);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);// 对认证证书来源的检查
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);// 从证书中检查SSL加密算

        //3)设置提交方式
        switch ($type) {
            case "GET":
                curl_setopt($ch, CURLOPT_HTTPGET, true);
                break;
            case "POST":
                curl_setopt($ch, CURLOPT_POST, true);
                break;
            case "PUT"://使用一个自定义的请求信息来代替"GET"或"HEAD"作为HTTP请                                                      求。这对于执行"DELETE" 或者其他更隐蔽的HTT
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PUT");
                break;
            case "DELETE":
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "DELETE");
                break;
        }


        //4)在HTTP请求中包含一个"User-Agent: "头的字符串。-----必设

        curl_setopt($ch, CURLOPT_USERAGENT, 'SSTS Browser/1.0');
        curl_setopt($ch, CURLOPT_ENCODING, 'gzip');

        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)'); // 模拟用户使用的浏览器
        //5)


        //3.抓取URL并把它传递给浏览器
        $res = curl_exec($ch);

        $result = json_decode($res, true);
        //4.关闭curl资源，并且释放系统资源
        curl_close($ch);
        if (empty($result))
            return $res;
        else
            return $result;

    }

    /**
     *环信根据时间条件下载历史消息文件
     */
    function getChatRecordFile($time) {
        $url = $this->url . 'chatmessages/' . $time;
        $header = [$this->getToken()];
        $result = $this->postCurl($url, '', $header, 'GET');
        return $result;
    }

    //下载内容，此类直接调用此方法
    public function downChat($time) {
        $path = LOG_PATH . 'Custom/';//设置根路径
        $sub_dir = substr($time, 0, 8);//截取时间的天如20180822作为文件夹
        //如果本地存贮了聊天文件，由于访问限制，每个文件都是一小时的聊天记录
        $find_file = realpath($path) . '/' . $sub_dir . '/' . $time;
        $info = [];
        if (file_exists($find_file)) {
            $txt = file_get_contents($find_file);
            if (empty(trim($txt))) {
                return ['state' => 0, 'msg' => '该时段暂无数据3'];
            }
            //这段代码是直接返回 然后入数据表
            $aa = explode("\n", trim($txt));
            foreach ($aa as $key => $val) {
                $info[$key] = json_decode($val, true);
            }
            return ['state' => 1, 'data' => $info];
        }

        $result = $this->getChatRecord($time); //调用下载方法，返回的是文件下载URL
        if (isset($result['error'])) {
            return ['state' => 0, 'msg' => '该时段暂无数据1'];
        }
        if (!isset($result['data'][0]['url'])) {
            return ['state' => 0, 'msg' => '该时段暂无数据2'];
        }
        //请求httpcopy方法，返回下载好的压缩文件
        $downData = $this->httpcopy($result['data'][0]['url'], $path);
        if ($downData == 'fail') {
            return ['state' => 0, 'msg' => '下载失败'];
        }
        //解压缩后返回文件路径
        $ungz = $this->unzipGz($downData);
        if ($ungz == 'fail') {
            return ['state' => 0, 'msg' => '解压失败'];
        }
        if (!file_exists($ungz)) {
            return ['state' => 0, 'msg' => '文件不存在'];
        }
        $txt = file_get_contents($ungz);
        if (empty(trim($txt))) {
            return ['state' => 0, 'msg' => '该时段暂无数据3'];
        }
        $aa = explode("\n", trim($txt));
        foreach ($aa as $key => $val) {
            $info[$key] = json_decode($val, true);
        }
        return ['state' => 1, 'data' => $info];
    }

    //下载远程文件
    public function httpcopy($url, $path, $files = "", $timeout = 60) {
        $file_a = empty($files) ? pathinfo($url, PATHINFO_BASENAME) : $files;
        //分割
        $file = explode('?', $file_a)[0];
        $sub_dir = substr($file, 0, 8);
        $dir = realpath($path) . '/' . $sub_dir;

        if (!is_dir($dir)) {
            @mkdir($dir, 0755, true);
        }
        $url = str_replace(" ", "%20", $url);
        $temp = file_get_contents($url);
        if (@file_put_contents($dir . '/' . $file, $temp)) {
            return $dir . '/' . $file;
        } else {
            return 'fail';
        }
    }

    //解压gz压缩包
    public function unzipGz($gz_file) {
        $buffer_size = 1000000; //限定大小
        $out_file_name = str_replace('.gz', '', $gz_file);
        $file = gzopen($gz_file, 'rb');
        $out_file = fopen($out_file_name, 'wb');
        if (!gzeof($file)) {
            fwrite($out_file, gzread($file, $buffer_size));
            fclose($out_file);
            gzclose($file);
            return $out_file_name;
        } else {
            return 'fail';
        }
    }

}